package ai.mspbots.service.query.message.consumer;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
 
@Component
public class KafkaConsumer {
    // logger
    private static final Logger logger = LoggerFactory.getLogger(KafkaConsumer.class);

    @KafkaListener(topics = "ms-apm", groupId = "ms-apm-kafka")
    public void listen(String message) {
        logger.info("Received Message in group 'ms-apm-kafka': {} ", message);
    }
}